package com.ytjj.qmyx.supplychain.common.kafka;

import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

@ConditionalOnProperty(prefix = "config.project", name = "enable", havingValue = "true")
public interface IAppActivationKafkaOut {

    String OUTPUT_MIDDLE_END_TRADE_TEST = "output_middle_end_trade_test";

    String OUTPUT_MIDDLE_END_TRADE = "output_middle_end_trade";

    /**
     * 测试用的通道
     * @return
     */
    @Output(OUTPUT_MIDDLE_END_TRADE_TEST)
    MessageChannel middleEndTradeTest();

    /**
     * 线上用
     * @return
     */
    @Output(OUTPUT_MIDDLE_END_TRADE)
    MessageChannel middleEndTrade();

}
